package ai.zixing.example02;

/**
 * 使用建造者模式
 *  1.目标类的构造方法要传入一个 builder 对象
 *  2.builder 类位于目标类的内部，并且使用 static 修饰
 *  3.builder 类对象提供内置的各种 set 方法，注意：set方法返回值是 builder 本身
 *  4.builder 类提供一个 builder(), 实现目标对象的创建
 */
public class RabbitMQClient3 {

    // 私有化构造
    private RabbitMQClient3(Builder builder) {

    }


    // 2.builder 类位于目标类的内部，并且使用 static 修饰
    public static class Builder {
        // 保证不可变对象的属性密闭性
        private String host = "127.0.0.1";
        private int port = 5672;
        private int mode;
        private String exchange;
        private String queue;
        private boolean isDurable = true;
        int connectionTimeout = 1000;

        // 3.builder 类对象提供内置的各种 set 方法，注意：set方法返回值是 builder 本身
        public Builder setHost(String host) {
            this.host = host;
            return this;
        }

        public Builder setPort(int port) {
            this.port = port;
            return this;
        }

        public Builder setMode(int mode) {
            this.mode = mode;
            return this;
        }

        public Builder setExchange(String exchange) {
            this.exchange = exchange;
            return this;
        }

        public Builder setQueue(String queue) {
            this.queue = queue;
            return this;
        }

        public Builder setDurable(boolean durable) {
            isDurable = durable;
            return this;
        }

        public Builder setConnectionTimeout(int connectionTimeout) {
            this.connectionTimeout = connectionTimeout;
            return this;
        }

        // 4.builder 类提供一个 builder(), 实现目标对象的创建
        public RabbitMQClient3 builder() {
            // 校验逻辑
            if(mode == 1){ //工作队列模式不需要设计交换机,但是队列名称一定要有
                if(exchange != null){
                    throw new RuntimeException("工作队列模式无需设计交换机");
                }
                if(queue == null || queue.trim().equals("")){
                    throw new RuntimeException("工作队列模式名称不能为空");
                }
                if(isDurable == false){
                    throw new RuntimeException("工作队列模式必须开启持久化");
                }
            }else if(mode == 2){ //路由模式必须设计交换机,但是不能设计队列
                if(exchange == null){
                    throw new RuntimeException("路由模式下必须设置交换机");
                }
                if(queue != null){
                    throw new RuntimeException("路由模式无须设计队列名称");
                }
            }
            return new RabbitMQClient3(this);
        }
    }

    public void sendMessage(String msg){

        System.out.println("发送消息......");
    }
}
